Node / meshtastic / Meshtastic-Android / files / feature / discovery / src / commonTest / kotlin / org / meshtastic / feature / discovery / DiscoveryPacketCollectionTest.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tf0883e@fileTb4b4b4:Te6edf3SuppressTb4b4b4(Ta5d6ff"Ta5d6ffMagicNumberTa5d6ff"Tb4b4b4)

Tff7b72package T7ee787org.meshtastic.feature.discovery

Tff7b72import T7ee787kotlinx.coroutines.SupervisorJob

Tff7b72import T7ee787kotlinx.coroutines.delay

Tff7b72import T7ee787kotlinx.coroutines.test.TestScope

Tff7b72import T7ee787kotlinx.coroutines.test.UnconfinedTestDispatcher

Tff7b72import T7ee787kotlinx.coroutines.test.runTest

Tff7b72import T7ee787okio.ByteString

Tff7b72import T7ee787okio.ByteString.Companion.toByteString

Tff7b72import T7ee787org.meshtastic.core.common.di.ApplicationCoroutineScope

Tff7b72import T7ee787org.meshtastic.core.database.entity.DiscoveryPresetResultEntity

Tff7b72import T7ee787org.meshtastic.core.database.entity.DiscoverySessionEntity

Tff7b72import T7ee787org.meshtastic.core.di.CoroutineDispatchers

Tff7b72import T7ee787org.meshtastic.core.model.ChannelOption

Tff7b72import T7ee787org.meshtastic.core.model.ConnectionState

Tff7b72import T7ee787org.meshtastic.core.model.DataPacket

Tff7b72import T7ee787org.meshtastic.core.model.MyNodeInfo

Tff7b72import T7ee787org.meshtastic.core.model.NodeAddress

Tff7b72import T7ee787org.meshtastic.core.repository.DiscoveryPacketCollector

Tff7b72import T7ee787org.meshtastic.core.repository.DiscoveryPacketCollectorRegistry

Tff7b72import T7ee787org.meshtastic.core.testing.FakeMeshPrefs

Tff7b72import T7ee787org.meshtastic.core.testing.FakeNodeRepository

Tff7b72import T7ee787org.meshtastic.core.testing.FakeRadioConfigRepository

Tff7b72import T7ee787org.meshtastic.core.testing.FakeRadioController

Tff7b72import T7ee787org.meshtastic.core.testing.FakeServiceRepository

Tff7b72import T7ee787org.meshtastic.feature.discovery.ai.DiscoverySummaryAiProvider

Tff7b72import T7ee787org.meshtastic.proto.Config

Tff7b72import T7ee787org.meshtastic.proto.Data

Tff7b72import T7ee787org.meshtastic.proto.LocalConfig

Tff7b72import T7ee787org.meshtastic.proto.MeshPacket

Tff7b72import T7ee787org.meshtastic.proto.Neighbor

Tff7b72import T7ee787org.meshtastic.proto.NeighborInfo

Tff7b72import T7ee787org.meshtastic.proto.PortNum

Tff7b72import T7ee787org.meshtastic.proto.Position

Tff7b72import T7ee787kotlin.test.Test

Tff7b72import T7ee787kotlin.test.assertEquals

Tff7b72import T7ee787kotlin.test.assertNull

Tff7b72import T7ee787kotlin.test.assertTrue

T8b949e/**

* Tests for edge cases in packet collection: duplicate packets, nodes without positions, and neighbor-info-only

* sightings (D023).

*/

Tff7b72class T56d364DiscoveryPacketCollectionTest Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3radioController Tff7b72= Te6edf3FakeRadioControllerTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3apply Tb4b4b4{ Te6edf3selectedDeviceAddress Tff7b72= Te6edf3DEFAULT_DEVICE_ADDRESS Tb4b4b4}

Tff7b72private Tff7b72val Te6edf3serviceRepository Tff7b72= Te6edf3FakeServiceRepositoryTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3apply Tb4b4b4{ Te6edf3setConnectionStateTb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectedTb4b4b4) Tb4b4b4}

Tff7b72private Tff7b72val Te6edf3nodeRepository Tff7b72= Te6edf3FakeNodeRepositoryTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3radioConfigRepository Tff7b72=

Te6edf3FakeRadioConfigRepositoryTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3apply Tb4b4b4{

Te6edf3setLocalConfigDirectTb4b4b4(

Te6edf3LocalConfigTb4b4b4(

Te6edf3lora Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3LoRaConfigTb4b4b4(Te6edf3use_preset Tff7b72= Tff7b72trueTb4b4b4, Te6edf3modem_preset Tff7b72= Te6edf3ChannelOptionTb4b4b4.Te6edf3LONG_FASTTb4b4b4.Te6edf3modemPresetTb4b4b4)Tb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72val Te6edf3collectorRegistry Tff7b72= Te6edf3PacketTestCollectorRegistryTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3discoveryDao Tff7b72= Te6edf3SharedInMemoryDiscoveryDaoTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3aiProvider Tff7b72= Te6edf3PacketTestAiProviderTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3meshPrefs Tff7b72= Te6edf3FakeMeshPrefsTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3apply Tb4b4b4{ Te6edf3setDeviceAddressTb4b4b4(Te6edf3DEFAULT_DEVICE_ADDRESSTb4b4b4) Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffcreateEngineTb4b4b4(Te6edf3testScopeTb4b4b4: Te6edf3TestScopeTb4b4b4)Tb4b4b4: Te6edf3DiscoveryScanEngine Tb4b4b4{

Tff7b72val Te6edf3testDispatcher Tff7b72= Te6edf3UnconfinedTestDispatcherTb4b4b4(Te6edf3testScopeTb4b4b4.Te6edf3testSchedulerTb4b4b4)

Tff7b72val Te6edf3dispatchers Tff7b72= Te6edf3CoroutineDispatchersTb4b4b4(Te6edf3io Tff7b72= Te6edf3testDispatcherTb4b4b4, Te6edf3main Tff7b72= Te6edf3testDispatcherTb4b4b4, Te6edf3default Tff7b72= Te6edf3testDispatcherTb4b4b4)

Tff7b72val Te6edf3appScope Tff7b72=

Tff7b72object Tb4b4b4: T56d364ApplicationCoroutineScope Tb4b4b4{

Tff7b72override Tff7b72val Te6edf3coroutineContext Tff7b72= Te6edf3testDispatcher Tff7b72+ Te6edf3SupervisorJobTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72return Te6edf3DiscoveryScanEngineTb4b4b4(

Te6edf3radioController Tff7b72= Te6edf3radioControllerTb4b4b4,

Te6edf3serviceRepository Tff7b72= Te6edf3serviceRepositoryTb4b4b4,

Te6edf3nodeRepository Tff7b72= Te6edf3nodeRepositoryTb4b4b4,

Te6edf3radioConfigRepository Tff7b72= Te6edf3radioConfigRepositoryTb4b4b4,

Te6edf3collectorRegistry Tff7b72= Te6edf3collectorRegistryTb4b4b4,

Te6edf3discoveryDao Tff7b72= Te6edf3discoveryDaoTb4b4b4,

Te6edf3aiProvider Tff7b72= Te6edf3aiProviderTb4b4b4,

Te6edf3applicationScope Tff7b72= Te6edf3appScopeTb4b4b4,

Te6edf3dispatchers Tff7b72= Te6edf3dispatchersTb4b4b4,

Te6edf3meshPrefs Tff7b72= Te6edf3meshPrefsTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72val Te6edf3testPresets Tff7b72= Te6edf3listOfTb4b4b4(Te6edf3ChannelOptionTb4b4b4.Te6edf3LONG_FASTTb4b4b4)

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffawaitDwellTb4b4b4(Te6edf3engineTb4b4b4: Te6edf3DiscoveryScanEngineTb4b4b4) Tb4b4b4{

Tff7b72while Tb4b4b4(Te6edf3engineTb4b4b4.Te6edf3scanStateTb4b4b4.Te6edf3value Tff7b72!is Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3DwellTb4b4b4) Tb4b4b4{

Te6edf3delayTb4b4b4(T79c0ff5T79c0ff0Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

T8b949e// region Duplicate packets

Tf0883e@Test

Tff7b72fun Td2a8ffduplicatePacketsFromSameNodeDeduplicateByNodeNumTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// Send two position packets from the same node

Tff7b72val Te6edf3meshPacket1 Tff7b72= Te6edf3positionPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff1T79c0ff1T79c0ff1T79c0ff1Tb4b4b4, Te6edf3latI Tff7b72= T79c0ff3T79c0ff7T79c0ff7T79c0ff7T79c0ff4T79c0ff9T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3lonI Tff7b72= Tff7b72-T79c0ff1T79c0ff2T79c0ff2T79c0ff4T79c0ff1T79c0ff9T79c0ff4T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3snr Tff7b72= T79c0ff5.0fTb4b4b4, Te6edf3rssi Tff7b72= Tff7b72-T79c0ff7T79c0ff0Tb4b4b4)

Tff7b72val Te6edf3meshPacket2 Tff7b72= Te6edf3positionPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff1T79c0ff1T79c0ff1T79c0ff1Tb4b4b4, Te6edf3latI Tff7b72= T79c0ff3T79c0ff7T79c0ff7T79c0ff7T79c0ff5T79c0ff0T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3lonI Tff7b72= Tff7b72-T79c0ff1T79c0ff2T79c0ff2T79c0ff4T79c0ff1T79c0ff9T79c0ff5T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3snr Tff7b72= T79c0ff8.0fTb4b4b4, Te6edf3rssi Tff7b72= Tff7b72-T79c0ff5T79c0ff5Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3meshPacket1Tb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff1T79c0ff1T79c0ff1T79c0ff1Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3meshPacket2Tb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff1T79c0ff1T79c0ff1T79c0ff1Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

T8b949e// Only one discovered node for nodeNum=1111

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3nodesTb4b4b4.Te6edf3sizeTb4b4b4, Ta5d6ff"Ta5d6ffDuplicate packets should map to a single node entryTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1T79c0ff1T79c0ff1T79c0ff1LTb4b4b4, Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3nodeNumTb4b4b4)

T8b949e// Second packet's SNR/RSSI should overwrite first

Te6edf3assertEqualsTb4b4b4(T79c0ff8.0fTb4b4b4, Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3snrTb4b4b4, Ta5d6ff"Ta5d6ffLater SNR should overwriteTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Tff7b72-T79c0ff5T79c0ff5Tb4b4b4, Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3rssiTb4b4b4, Ta5d6ff"Ta5d6ffLater RSSI should overwriteTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffduplicatePacketsCountMessagesAccumulativelyTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// Send 3 text messages from same node

Te6edf3repeatTb4b4b4(T79c0ff3Tb4b4b4) Tb4b4b4{ Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3textMessagePacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff2T79c0ff2T79c0ff2T79c0ff2Tb4b4b4)Tb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff2T79c0ff2T79c0ff2T79c0ff2Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3nodesTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff3Tb4b4b4, Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3messageCountTb4b4b4, Ta5d6ff"Ta5d6ffMessage count should accumulate across duplicate packetsTa5d6ff"Tb4b4b4)

Tb4b4b4}

T8b949e// endregion

T8b949e// region Nodes without positions

Tf0883e@Test

Tff7b72fun Td2a8ffnodeWithoutPositionHasNullLatLonTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// Send a text message with no position data

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3textMessagePacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff3T79c0ff3T79c0ff3T79c0ff3Tb4b4b4)Tb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff3T79c0ff3T79c0ff3T79c0ff3Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3nodesTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3latitudeTb4b4b4, Ta5d6ff"Ta5d6ffNode without position should have null latitudeTa5d6ff"Tb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3longitudeTb4b4b4, Ta5d6ff"Ta5d6ffNode without position should have null longitudeTa5d6ff"Tb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3distanceFromUserTb4b4b4, Ta5d6ff"Ta5d6ffNode without position should have null distanceTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffnodeWithZeroPositionTreatedAsNoPositionTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// Position of 0,0 is treated as invalid/no fix

Tff7b72val Te6edf3packet Tff7b72= Te6edf3positionPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff4T79c0ff4T79c0ff4T79c0ff4Tb4b4b4, Te6edf3latI Tff7b72= T79c0ff0Tb4b4b4, Te6edf3lonI Tff7b72= T79c0ff0Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff4T79c0ff4T79c0ff4T79c0ff4Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3nodesTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3distanceFromUserTb4b4b4, Ta5d6ff"Ta5d6ffZero-position node should have null distanceTa5d6ff"Tb4b4b4)

Tb4b4b4}

T8b949e// endregion

T8b949e// region Neighbor-info-only sightings

Tf0883e@Test

Tff7b72fun Td2a8ffneighborInfoOnlyNodeIsMarkedAsMeshTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// Send a neighbor info packet that references node 5555 as a mesh neighbor

Tff7b72val Te6edf3niPacket Tff7b72= Te6edf3neighborInfoPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9T79c0ff9Tb4b4b4, Te6edf3neighborNodeIds Tff7b72= Te6edf3listOfTb4b4b4(T79c0ff5T79c0ff5T79c0ff5T79c0ff5Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3niPacketTb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9T79c0ff9Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

T8b949e// Node 5555 should appear as a mesh neighbor even though we never received a direct packet from it

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3meshNode Tff7b72= Te6edf3nodesTb4b4b4.Te6edf3find Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3nodeNum Tff7b72=Tff7b72= T79c0ff5T79c0ff5T79c0ff5T79c0ff5L Tb4b4b4}

Te6edf3assertTrueTb4b4b4(Te6edf3meshNode Tff7b72!Tff7b72= Tff7b72nullTb4b4b4, Ta5d6ff"Ta5d6ffNeighbor-info-only node should be persistedTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffmeshTa5d6ff"Tb4b4b4, Te6edf3meshNodeTb4b4b4.Te6edf3neighborTypeTb4b4b4, Ta5d6ff"Ta5d6ffNeighbor-info-only node should have 'mesh' typeTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffneighborInfoDoesNotOverrideDirectTypeTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// First: receive a direct packet from node 6666

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(

Te6edf3positionPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff6T79c0ff6T79c0ff6T79c0ff6Tb4b4b4, Te6edf3latI Tff7b72= T79c0ff3T79c0ff7T79c0ff7T79c0ff7T79c0ff4T79c0ff9T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3lonI Tff7b72= Tff7b72-T79c0ff1T79c0ff2T79c0ff2T79c0ff4T79c0ff1T79c0ff9T79c0ff4T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3snr Tff7b72= T79c0ff1T79c0ff0fTb4b4b4, Te6edf3rssi Tff7b72= Tff7b72-T79c0ff4T79c0ff0Tb4b4b4)Tb4b4b4,

Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff6T79c0ff6T79c0ff6T79c0ff6Tb4b4b4)Tb4b4b4,

Tb4b4b4)

T8b949e// Then: receive neighbor info that also references 6666

Tff7b72val Te6edf3niPacket Tff7b72= Te6edf3neighborInfoPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff8T79c0ff8T79c0ff8T79c0ff8Tb4b4b4, Te6edf3neighborNodeIds Tff7b72= Te6edf3listOfTb4b4b4(T79c0ff6T79c0ff6T79c0ff6T79c0ff6Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3niPacketTb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff8T79c0ff8T79c0ff8T79c0ff8Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3directNode Tff7b72= Te6edf3nodesTb4b4b4.Te6edf3find Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3nodeNum Tff7b72=Tff7b72= T79c0ff6T79c0ff6T79c0ff6T79c0ff6L Tb4b4b4}

Te6edf3assertTrueTb4b4b4(Te6edf3directNode Tff7b72!Tff7b72= Tff7b72nullTb4b4b4, Ta5d6ff"Ta5d6ffNode should be persistedTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffdirectTa5d6ff"Tb4b4b4, Te6edf3directNodeTb4b4b4.Te6edf3neighborTypeTb4b4b4, Ta5d6ff"Ta5d6ffDirect type should not be overridden by neighbor-infoTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1T79c0ff0fTb4b4b4, Te6edf3directNodeTb4b4b4.Te6edf3snrTb4b4b4, Ta5d6ff"Ta5d6ffSNR from direct packet should be preservedTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffneighborInfoMultipleNeighborsAllRecordedTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

Tff7b72val Te6edf3niPacket Tff7b72= Te6edf3neighborInfoPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff7T79c0ff7T79c0ff7T79c0ff7Tb4b4b4, Te6edf3neighborNodeIds Tff7b72= Te6edf3listOfTb4b4b4(T79c0ff1T79c0ff0T79c0ff1Tb4b4b4, T79c0ff1T79c0ff0T79c0ff2Tb4b4b4, T79c0ff1T79c0ff0T79c0ff3Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3niPacketTb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff7T79c0ff7T79c0ff7T79c0ff7Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

T8b949e// Node 7777 (the sender) + 3 mesh neighbors

Tff7b72val Te6edf3meshNodes Tff7b72= Te6edf3nodesTb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3neighborType Tff7b72=Tff7b72= Ta5d6ff"Ta5d6ffmeshTa5d6ff" Tb4b4b4}

Te6edf3assertEqualsTb4b4b4(T79c0ff3Tb4b4b4, Te6edf3meshNodesTb4b4b4.Te6edf3sizeTb4b4b4, Ta5d6ff"Ta5d6ffAll neighbor IDs from NeighborInfo should be recordedTa5d6ff"Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3meshNodesTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3nodeNum Tb4b4b4}Tb4b4b4.Te6edf3containsAllTb4b4b4(Te6edf3listOfTb4b4b4(T79c0ff1T79c0ff0T79c0ff1LTb4b4b4, T79c0ff1T79c0ff0T79c0ff2LTb4b4b4, T79c0ff1T79c0ff0T79c0ff3LTb4b4b4)Tb4b4b4)Tb4b4b4)

Tb4b4b4}

T8b949e// endregion

T8b949e// region Helpers

Tff7b72private Tff7b72fun Td2a8ffcreateMyNodeInfoTb4b4b4(Te6edf3nodeNumTb4b4b4: Tffa657Int Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0Tb4b4b4) Tff7b72= Te6edf3MyNodeInfoTb4b4b4(

Te6edf3myNodeNum Tff7b72= Te6edf3nodeNumTb4b4b4,

Te6edf3hasGPS Tff7b72= Tff7b72trueTb4b4b4,

Te6edf3model Tff7b72= Ta5d6ff"Ta5d6ffTestModelTa5d6ff"Tb4b4b4,

Te6edf3firmwareVersion Tff7b72= Ta5d6ff"Ta5d6ff2.0.0Ta5d6ff"Tb4b4b4,

Te6edf3couldUpdate Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3shouldUpdate Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3currentPacketId Tff7b72= T79c0ff1LTb4b4b4,

Te6edf3messageTimeoutMsec Tff7b72= T79c0ff5T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,

Te6edf3minAppVersion Tff7b72= T79c0ff1Tb4b4b4,

Te6edf3maxChannels Tff7b72= T79c0ff8Tb4b4b4,

Te6edf3hasWifi Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3channelUtilization Tff7b72= T79c0ff0fTb4b4b4,

Te6edf3airUtilTx Tff7b72= T79c0ff0fTb4b4b4,

Te6edf3deviceId Tff7b72= Ta5d6ff"Ta5d6fftest-deviceTa5d6ff"Tb4b4b4,

Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffpositionPacketTb4b4b4(Te6edf3fromTb4b4b4: Tffa657IntTb4b4b4, Te6edf3latITb4b4b4: Tffa657IntTb4b4b4, Te6edf3lonITb4b4b4: Tffa657IntTb4b4b4, Te6edf3snrTb4b4b4: Tffa657Float Tff7b72= T79c0ff5.5fTb4b4b4, Te6edf3rssiTb4b4b4: Tffa657Int Tff7b72= Tff7b72-T79c0ff7T79c0ff0Tb4b4b4)Tb4b4b4: Te6edf3MeshPacket Tb4b4b4{

Tff7b72val Te6edf3posPayload Tff7b72= Te6edf3PositionTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3encodeTb4b4b4(Te6edf3PositionTb4b4b4(Te6edf3latitude_i Tff7b72= Te6edf3latITb4b4b4, Te6edf3longitude_i Tff7b72= Te6edf3lonITb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3data Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3POSITION_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3posPayloadTb4b4b4)

Tff7b72return Te6edf3MeshPacketTb4b4b4(Te6edf3from Tff7b72= Te6edf3fromTb4b4b4, Te6edf3decoded Tff7b72= Te6edf3dataTb4b4b4, Te6edf3rx_snr Tff7b72= Te6edf3snrTb4b4b4, Te6edf3rx_rssi Tff7b72= Te6edf3rssiTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8fftextMessagePacketTb4b4b4(Te6edf3fromTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3MeshPacket Tb4b4b4{

Tff7b72val Te6edf3data Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Ta5d6ff"Ta5d6ffhelloTa5d6ff"Tb4b4b4.Te6edf3encodeToByteArrayTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)Tb4b4b4)

Tff7b72return Te6edf3MeshPacketTb4b4b4(Te6edf3from Tff7b72= Te6edf3fromTb4b4b4, Te6edf3decoded Tff7b72= Te6edf3dataTb4b4b4, Te6edf3rx_snr Tff7b72= T79c0ff3.0fTb4b4b4, Te6edf3rx_rssi Tff7b72= Tff7b72-T79c0ff8T79c0ff0Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffneighborInfoPacketTb4b4b4(Te6edf3fromTb4b4b4: Tffa657IntTb4b4b4, Te6edf3neighborNodeIdsTb4b4b4: Te6edf3ListTff7b72<Tffa657IntTff7b72>Tb4b4b4)Tb4b4b4: Te6edf3MeshPacket Tb4b4b4{

Tff7b72val Te6edf3neighbors Tff7b72= Te6edf3neighborNodeIdsTb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3NeighborTb4b4b4(Te6edf3node_id Tff7b72= Tffa657itTb4b4b4) Tb4b4b4}

Tff7b72val Te6edf3ni Tff7b72= Te6edf3NeighborInfoTb4b4b4(Te6edf3node_id Tff7b72= Te6edf3fromTb4b4b4, Te6edf3neighbors Tff7b72= Te6edf3neighborsTb4b4b4)

Tff7b72val Te6edf3payload Tff7b72= Te6edf3NeighborInfoTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3encodeTb4b4b4(Te6edf3niTb4b4b4)Tb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3data Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3NEIGHBORINFO_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3payloadTb4b4b4)

Tff7b72return Te6edf3MeshPacketTb4b4b4(Te6edf3from Tff7b72= Te6edf3fromTb4b4b4, Te6edf3decoded Tff7b72= Te6edf3dataTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffdataPacketTb4b4b4(Te6edf3fromTb4b4b4: Tffa657IntTb4b4b4) Tff7b72= Te6edf3DataPacketTb4b4b4(

Te6edf3to Tff7b72= Te6edf3NodeAddressTb4b4b4.Te6edf3ID_BROADCASTTb4b4b4,

Te6edf3bytes Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4,

Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3POSITION_APPTb4b4b4.Te6edf3valueTb4b4b4,

Te6edf3from Tff7b72= Ta5d6ff"Ta5d6ff!Tffd700${Te6edf3fromTb4b4b4.Te6edf3toStringTb4b4b4(T79c0ff1T79c0ff6Tb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4,

Te6edf3hopStart Tff7b72= T79c0ff3Tb4b4b4,

Te6edf3hopLimit Tff7b72= T79c0ff3Tb4b4b4,

Tb4b4b4)

T8b949e// endregion

Tff7b72private Tff7b72companion Tff7b72object Tb4b4b4{

Tff7b72const Tff7b72val Te6edf3DEFAULT_DEVICE_ADDRESS Tff7b72= Ta5d6ff"Ta5d6ffx:TEST-DEVICETa5d6ff"

Tb4b4b4}

Tb4b4b4}

T8b949e// region Inline test doubles

Tff7b72private Tff7b72class T56d364PacketTestCollectorRegistry Tb4b4b4: Te6edf3DiscoveryPacketCollectorRegistry Tb4b4b4{

Tff7b72override Tff7b72var Te6edf3collectorTb4b4b4: Te6edf3DiscoveryPacketCollector? Tff7b72= Tff7b72null

Tb4b4b4}

Tff7b72private Tff7b72class T56d364PacketTestAiProvider Tb4b4b4: Te6edf3DiscoverySummaryAiProvider Tb4b4b4{

Tff7b72override Tff7b72val Te6edf3isAvailableTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72false

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgenerateSessionSummaryTb4b4b4(

Te6edf3sessionTb4b4b4: Te6edf3DiscoverySessionEntityTb4b4b4,

Te6edf3presetResultsTb4b4b4: Te6edf3ListTff7b72<Te6edf3DiscoveryPresetResultEntityTff7b72>Tb4b4b4,

Tb4b4b4)Tb4b4b4: Tffa657String? Tff7b72= Tff7b72null

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgeneratePresetSummaryTb4b4b4(Te6edf3resultTb4b4b4: Te6edf3DiscoveryPresetResultEntityTb4b4b4)Tb4b4b4: Tffa657String? Tff7b72= Tff7b72null

Tb4b4b4}